"use strict";

/**
 * sql事物
 */
class Transactional {
  constructor(cloud) {
    this.cloud = cloud;
  }

  /**
   * 创建事物连接
   */
  async beginTransaction() {
    return await this.cloud.dataspace.beginTransaction();
  }
  
  /**
   * 事物提交
   */
  async  commit(conn) {
    return await conn.commit();
  }

  /**
   * 事物回滚
   */
  async  rollback(conn) {
    return await conn.rollback();
  }
}
module.exports = Transactional;